package com.wang.test

import com.streamxhub.streamx.flink.core.scala.FlinkStreamTable

object ScalaFlinkSqlJob extends FlinkStreamTable {


    override def handle(): Unit = {

        context.sql("flinksql")
    }
}
